import com.alibaba.fastjson2.JSONObject;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.junit.Test;

import javax.jms.*;

public class Producer {

    @Test
    public void testQueueProducer() throws Exception {
        // 创建activemq connection factory
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://121.5.145.35:61616");
        // 通过connection factory创建连接
        Connection connection = connectionFactory.createConnection();
        // 打开连接
        connection.start();

        // 通过连接创建会话
        // 参数：1.是否开启事务 2.自动应答
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 创建队列
//        Queue queue = session.createQueue("queueueueueueue");
        Topic topic = session.createTopic("topic3");
        // 创建生产者
//        MessageProducer producer = session.createProducer(queue);
        MessageProducer producer = session.createProducer(topic);
        // 创建消息
        TextMessage textMessage = session.createTextMessage("hello world");
        // 发送消息
        producer.send(textMessage);

        // 关闭资源
        producer.close();
        session.close();
        connection.close();
    }

    @Test
    public void TestTopicConsumer() throws Exception {
        //1、创建工厂连接对象，需要制定ip和端口号
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://121.5.145.35:61616");
        //2、使用连接工厂创建一个连接对象
        Connection connection = connectionFactory.createConnection();
        //3、开启连接
        connection.start();

        //4、使用连接对象创建会话（session）对象
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5、使用会话对象创建目标对象，包含queue和topic（一对一和一对多）
//        Queue queue = session.createQueue("rjw");
        Topic topic3 = session.createTopic("topic3");
        //6. 创建消费者
        MessageConsumer consumer = session.createConsumer(topic3);
        //7、向consumer对象中设置一个messageListener对象，用来接收消息
        consumer.setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                // 收到消息时调用
                try {
                    if (message instanceof TextMessage) {
                        // 获得textmessage，平时开发中可以放json字符串
                        TextMessage textMessage = (TextMessage) message;
                        System.out.println(textMessage.getText());
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }

            }
        });
        //8、程序等待接收用户消息，阻塞
        System.in.read();
        //9、关闭资源
        consumer.close();
        session.close();
        connection.close();
    }


}
